///**
// * @author MrShun
// * @version 1.0
// * @Date 2017-09-14
// */
//public class AvatarMQ {
//
//    private static ProducerMessageHook hook = new ProducerMessageHook() {
//        public ConsumerAckMessage hookMessage(Message message) {
//            System.out.printf("AvatarMQConsumer1 收到消息编号:%s,消息内容:%s\n", message.getMsgId(), new String(message.getBody()));
//            ConsumerAckMessage result = new ConsumerAckMessage();
//            result.setStatus(ConsumerAckMessage.SUCCESS);
//            return result;
//        }
//    };
//
//    public static void main(String[] args) {
//        AvatarMQConsumer consumer = new AvatarMQConsumer("127.0.0.1:18888", "AvatarMQ-Topic-1", hook);
//        consumer.init();
//        consumer.setClusterId("AvatarMQCluster");
//        consumer.receiveMode();
//        consumer.start();
//    }
//}
